package com.millstein.realtime.util;

import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class ThreadPoolUtil {

    private final static ThreadPoolExecutor threadPool;

    static {
        threadPool = new ThreadPoolExecutor(
                200,
                300,
                120,
                TimeUnit.SECONDS,
                new LinkedBlockingQueue<>(300)
        );

    }

    public static ThreadPoolExecutor getThreadPool() {
        return threadPool;
    }
}
